package kafka

import (
	"core/config"
)

var (
	Config = &KafkaConfig{}
)

func init() {
	config.ConfigViper.UnmarshalKey("kafka", Config)

}
